# 1使用虚拟环境
#     创建项目时使用虚拟环境
# 2、安装celery
#     pip install celery
# 3、安装redis
#     pip install redis
# 4、win再安装eventlet
#     pip install eventlet
import time

from celery import Celery

# 消息中间件 使用redis库1
broker = 'redis://127.0.0.1:6379/1'
# 结果存储  使用redis库2
backend = 'redis://127.0.0.1:6379/2'
# 实例化得到redis的app对象
app = Celery('demo', broker=broker, backend=backend)


# 编写任务
@app.task  # 使用装饰器装饰  才是celery任务
def add(a,b):
    print("打印结果是", a + b)
    time.sleep(1)
    return a + b
